package com.gagakuai.bpm.common.constants;

/*
 * @program: mss_server
 * @description: mq常量
 * @author: houhong
 * @create: 2022-03-24 14:35
 */
public class RabbitMqConstants {


    /*
     * rabbit定义备份交换机参数
     */
    public static final String ALTER_EXCHANGE_DEFINE = "alternate-exchange";


    /*
     * bpm测试队列
     */
    public static final String BPM_TEST_QUEUE_NAME = "bpm-test-queue";

    /*
     * bpm死信队列
     */
    public static final String BPM_DEAD_QUEUE_NAME = "with-dead-queue";

    /*
     * bpm撤销队列
     */
    public static final String BPM_WITH_DRAW_QUEUE_NAME = "with-draw-queue";

    /*
     * bpm取回队列
     */
    public static final String BPM_WITH_RETURN_QUEUE_NAME = "with-return-queue";

    /*
     * bpm撤销到上一步队列
     */
    public static final String BPM_WITH_DRAW_LAST_STEP_QUEUE_NAME = "with-draw-last-step-queue";

    /*
     * bpm撤销到第一步队列
     */
    public static final String BPM_WITH_DRAW_FIRST_STEP_QUEUE_NAME = "with-draw-first-step-queue";

    /*
     * bpm 同步人员信息
     */
    public static final String BPM_WITH_SYNC_ACCOUNT_QUEUE_NAME = "mss-sync-queue";


    /*
     * bpm测信队列路由key
     */
    public static final String BPM_TEST_QUEUE_MATCH_ROUTING_KEY = "bpm.test";
    /*
     * bpm死信队列路由key
     */
    public static final String BPM_DEAD_QUEUE_MATCH_ROUTING_KEY = "bpm.dead.msg";

    /*
     * bpm撤销队列路由键
     */
    public static final String BPM_WITH_DRAW_SERVICE_MATCH_ROUTING_KEY = "bpm.with.draw";

    /*
     * bpm撤销上一步队列路由键
     */
    public static final String BPM_WITH_DRAW_LAST_STEP_SERVICE_MATCH_ROUTING_KEY = "bpm.with.draw.last.step";

    /*
     * bpm撤销第一步队列路由键
     */
    public static final String BPM_WITH_DRAW_FIRST_STEP_SERVICE_MATCH_ROUTING_KEY = "bpm.with.draw.first.step";

    /*
     * bpm 发起人取回流程队列路由键
     */
    public static final String BPM_WITH_RETURN_FIRST_STEP_SERVICE_MATCH_ROUTING_KEY = "bpm.with.return.first.step";

    /*
     * bpm同步员工路由键
     */
    public static final String BPM_SYNC_ACCOUNT_MATCH_ROUTING_KEY = "bpm.sync.account";


    /*
     * bpm_topic_key
     */
    public static final String BPM_TOPIC_EXCHANGE = "bpm_topicExchange";

    /*
     * 设置备胎交换机，在消息未被路由的时候，存在这里面
     */
    public static final String DEFAULT_EXCHANGE = "bpm_defaultExchange";

    /*
     * 定义死信队列交换机
     */
    public static final String BPM_MSG_DEAD_EXCHANGE = "bpm_dead_exchange";
    // -------------------------------------------------

    public static final String PRE_FETCH_EXCHANGE = "preFetchTopicExchange";

    public static final String PRE_FETCH_QUEUE_NAME = "preFetchQueueName";

    public static final String PRE_FETCH_ROUTING_KEY = "preFetchRoutingKey";


    /*
     * 死信队列 交换机标识符
     */
    public static final String DEAD_LETTER_QUEUE_KEY = "x-dead-letter-exchange";

    /*
     * 死信队列路由key
     */
    public static final String DEAD_LETTER_ROUTE_KEY = "x-dead-letter-routing-key";


    /*
     * 实际消费队列
     * message失效后进入的队列，也就是实际的消费队列
     */
    public static final String PROCESS_QUEUE = "process.queue";

    /*
     * 处理的交换器
     */
    public static final String PROCESS_EXCHANGE = "process.queue.exchange";


    // ----------------BASIC QUEUE
    public static final String BASIC_QUEUE_EXCHANGE = "basicExchange";

    public static final String BASIC_QUEUE = "basicQueue";

    public static final String BASIC_QUEUE_ROUTING_KEY = "basicQueueRoutingKey.#";

    public static final String BASIC_QUEUE_DEAD_LETTER_EXCHANGE = "basicQueueDeadLetterExchange";

    public static final String BASIC_QUEUE_DEAD_LETTER_ROUTING_KEY = "basicQueueDeadLetterRoutingKey";

    public static final String BASIC_QUEUE_DEAD_LETTER_QUEUE = "basicQueueDeadLetterQueue";


    /*========================回调死信==================================================*/
    /*
     * 回调死信交换机
     */
    public static final String BPM_CALLBACK_DEAD_EXCHANGE = "bpm_callback_dead_exchange";

    /*
     * bpm异常数据队列
     */
    public static final String BPM_EXCEPTION_CALLBACK_QUEUE_NAME = "bpm-callback-queue";

    /*
     * bpm确认队列
     */
    public static final String BPM_CALLBACK_ACK_QUEUE_NAME = "bpm-callback-ack-queue";

    /*
     * bpm回调死信队列
     */
    public static final String BPM_CALLBACK_DEAD_QUEUE_NAME = "callback-dead-queue";

    /*
     * bpm死信队列路由key
     */
    public static final String BPM_CALLBACK_DEAD_QUEUE_MATCH_ROUTING_KEY = "bpm.callback.dead.msg";

    /*
     * bpm异常数据回调路由键
     */
    public static final String BPM_EXCEPTION_CALLBACK_ROUTKING_KEY = "bpm.callback.route.key";

    /*
     * bpm异常数据确认路由键
     */
    public static final String BPM_CALLBACK_ACK_ROUTKING_KEY = "bpm.callback.ack.route.key";

}